/**
 * 上海中赢金融信息服务有限公司
 * Copyright (c) 2017-2027 Chinazyjr,Inc.All Rights Reserved.
 */

package com.sys.midware.hbase.util;

import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.Map.Entry;

import org.apache.hadoop.hbase.util.Bytes;

import com.sys.midware.hbase.model.HbaseColumn;
import com.sys.midware.hbase.model.HbaseRow;

/**
 * <b>ClassName:</b> HbaseUtil.java <br/>
 * <b>Description:</b> TODO <br/>
 * <b>Date:</b>     2015年10月26日 下午8:01:11<br/> 
 * @author   mobing
 * @version  	 
 */
public class HbaseUtil {
    
    
    public static HbaseRow convertToHbaseRow(String columnFamilyName,Map<String, String> columnMap) {
        // create column
        Set<HbaseColumn> columns = new HashSet<HbaseColumn>();
        for (Entry<String, String> entry : columnMap.entrySet()) {
            columns.add(new HbaseColumn(columnFamilyName, entry.getKey(), entry.getValue()));
        }
        byte[] rowkey = Bytes.toBytes(columnMap.get("id"));
        HbaseRow e = new HbaseRow(rowkey, columns);
        return e;
    }
}

